package com.yupi.yuojbackendquestionservice.rabbitmq;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class MyMessageProducer {

    @Resource
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String exchange, String routingKey, String message) {
        //rabbitTemplates就是RabbitMQ的客户端 里面convertAndSend的方法进行发送消息
        // 发送到exchange交换机（快递站） 路由键routingKey（消息的标识）不采用的话就是广播的方式进行发送消息 消息内容message
        rabbitTemplate.convertAndSend(exchange, routingKey, message);
    }

}
